package cn.bb.test;

import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class Demo2 {
    public static void main(String[] args) throws Exception{
        //接收端的程序
        //创建一个字节数组用来接收数据
        byte[] buf = new byte[1024];
        //定义一个DatagramSocket对象，监听的端口号为8954
        DatagramSocket ds = new DatagramSocket(8954);
        //定义一个DatagramPacket对象，用于接收数据
        DatagramPacket dp = new DatagramPacket(buf,1024);
        System.out.println("等待接收数据");
        ds.receive(dp);//等待接收数据，如果没有数据会阻塞
        //获得的内容、长度。IP地址和端口号
        String str = new String(dp.getData(),0,dp.getLength())+"from"+
                dp.getAddress().getHostAddress()+":"+dp.getPort();
        System.out.println(str);
        ds.close();
    }
}
